package cn.lgwen.candy.runtime.core;

import cn.lgwen.candy.runtime.operator.SourceOperator;

/**
 * 2019/12/25
 * aven.wu
 * danxieai258@163.com
 * O out put type
 */
public class SourceStream<O> extends Stream<O> {

    private SourceOperator<O> sourceOperator;

    public SourceStream(Environment environment) {
        super(environment);
    }

    public void setSourceOperator(SourceOperator<O> sourceOperator) {
        this.sourceOperator = sourceOperator;
    }

    public SourceOperator<O> getSourceOperator() {
        return sourceOperator;
    }

}
